package com.qfedu.edu.utils;
import org.apache.tomcat.util.threads.ThreadPoolExecutor;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.TimeUnit;

public class ThreadPoolUtils {
    //通知的线程池对象
    public static ThreadPoolExecutor notifyThreadPool = new ThreadPoolExecutor(
            10, 100, 10, TimeUnit.SECONDS,
            new ArrayBlockingQueue<>(8192)
    );

    public static ThreadPoolExecutor getNotifyThreadPool() {
        return notifyThreadPool;
    }
}
